package com.uatair.common.service;

import com.uatair.common.kafka.domain.protobuf.FlightProto;

/**
 * 无人机数据服务接口
 */
public interface DroneDataService {
    /**
     * 发送飞行记录到Kafka
     * @param flightRecord 飞行记录
     * @return 发送是否成功
     */
    boolean sendFlightRecord(FlightProto.FlightRecord flightRecord);

    /**
     * 处理接收到的飞行记录（供Kafka监听器调用）
     * @param recordBytes 二进制格式的飞行记录
     */
    void processFlightRecord(String recordBytes);
}